package com.smsc.headend.task.engine.message.bind;

import com.smsc.headend.module.task.consts.TaskKafkaTopic;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface TaskBind {


    /**
     * 发消息的通道
     *
     * @return
     */
    @Output(TaskKafkaTopic.TASK_RESULT_BACK)
    MessageChannel sendDemoMessage();
    /**
     * 收消息的通道
     *
     * @return
     */
    @Input(TaskKafkaTopic.TASK_SEND_TO_UTE)
    SubscribableChannel recieveDemoMessage();
}
